# -*- coding: utf-8 -*-
from datetime import timedelta

from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor
from jms.time_sensor.time_after_00_30 import time_after_00_30

dwd_yl_tmsnew_tms_shipment_base_hf_23 = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="dwd_yl_tmsnew_tms_shipment_base_hf_23",
    filepath='/dw/hive/jms_dwd.db/external/dwd_yl_tmsnew_tms_shipment_base_hf/dt={{ execution_date | cst_ds }}-23',
    execution_timeout=timedelta(minutes=120),
    email=['jarl.huang@jtexpress.com','yl_bigdata@yl-scm.com'],
    retries=2,
)
dwd_yl_tmsnew_tms_shipment_base_hf_23  <<  time_after_00_30
